package initialize

import (
	"fmt"
	"github.com/beanstalkd/go-beanstalk"
)

func MustNewBeanstalkd(dsn string) *beanstalk.Conn {
	conn, err := beanstalk.Dial("tcp", dsn)
	if err != nil {
		fmt.Println("beanstalkd消息队列连接失败", err)
	}
	return conn
}
